package org.apache.flink.runtime.resourceconsumer;

import org.apache.flink.api.common.ConsumerID;
import org.apache.flink.runtime.ResourceException;

/** Exception indicating that resource consume has not been finished. */
public class ConsumeNotFinishedException extends ResourceException {
    private static final long serialVersionUID = 611413276562570622L;

    public ConsumeNotFinishedException(ConsumerID jobId) {
        super("The job (" + jobId + ") has not been finished.");
    }
}
